package com.xbstar.datafusion.databus;

import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSONObject;

/**
 * Created by jiwenfei on 2018/1/30 16:34 .
 */
@Service
public class DataBusManage {
    public void send2Controller(String data){
        /**
         * 往kafka 消息总线  发送消息 topicname=controllerget
         */
    }
   
	/**
	 * 把数据发送到数据总线
	 * @param pkg
	 */
	public void send2System(JSONObject pkg) {
		/**
         * 往kafka 消息总线  发送消息 topicname=controllersend
         */
		
	}

}
